一、RabbitMQ安装与测试连接 |
您所在的位置:网站首页 › rabbitmq 远程连接 › 一、RabbitMQ安装与测试连接 |
一、下载NuGet支持的RabbitMQ.Client客户端库与安装RabbitMQ服务。
1、安装客户端库操作服务。
2、安装服务。 https://www.rabbitmq.com/install-windows.html 步骤一、下载Erlang。 步骤二、下载RabbitMQ服务 采纳版本。
3、运行服务: 1、执行rabbitmq命令行工具(rabbitmqctl ): rabbitmqctl -q status //打印了一些rabbitmq服务状态信息,包括内存,硬盘,和使用erlong的版本信息 rabbitmqctl list_queues //查看所有队列消息 首先创建一个控制台程序,用来将消息发送到RabbitMQ的消息队列中,代码如下: ![]() ![]()
点击队列名进入
首先,需要创建一个ConnectionFactory,设置目标,由于是在本机,所以设置为localhost,如果RabbitMQ不在本机,只需要设置目标机器的IP地址或者机器名称即可,然后设置前面创建的用户名Bruce和密码Bruce123456。 紧接着要创建一个Channel,如果要发送消息,需要创建一个队列,然后将消息发布到这个队列中。在创建队列的时候,只有RabbitMQ上该队列不存在,才会去创建。消息是以二进制数组的形式传输的,所以如果消息是实体对象的话,需要序列化和然后转化为二进制数组。 现在客户端发送代码已经写好了,运行之后,消息会发布到RabbitMQ的消息队列中,现在需要编写服务端的代码连接到RabbitMQ上去获取这些消息。 自同样,创建一个名为Receive的服务端控制台应用程序,服务端代码如下:![]() ![]()
和发送一样,首先需要定义连接,然后声明消息队列。要接收消息,需要定义一个Consume,然后从消息队列中不断Dequeue消息,然后处理。 现在发送端和接收端的代码都写好了,运行发送端,发送消息: 现在,名为hello的消息队列中,发送了一条消息。这条消息存储到了RabbitMQ的服务器上了。使用rabbitmqctl 的list_queues可以查看所有的消息队列,以及里面的消息个数,可以看到,目前Rabbitmq上只有一个消息队列,里面只有一条消息: D:\Program Files\RabbitMQ Server\rabbitmq_server-3.4.2\sbin>rabbitmqctl list_queues Listing queues ... hello 1现在运行接收端程序,如下: 可以看到,已经接受到了客户端发送的Hello World,现在再来看RabitMQ上的消息队列信息: 命令行查看: D:\Program Files\RabbitMQ Server\rabbitmq_server-3.4.2\sbin>rabbitmqctl list_queues Listing queues ... hello 0可以看到,hello这个队列中的消息队列个数为0,这表示,当接收端,接收到消息之后,RabbitMQ上就把这个消息删掉了。 自定义环境变量 1、erl环境变量配置。 (1)erl环境变量配置。 ERLANG_HOME=C:\Program Files\erl10.3
1、RabbitMQ环境变量配置。 (1)RabbitMQ的安装位置,以及安装的版本,我的版本为3.7.3。 RABBITMQ_SERVER=C:\Program Files\RabbitMQ Server\rabbitmq_server-3.7.14 (2)在Path中加入。 %RABBITMQ_SERVER%\sbin;
|
今日新闻 |
推荐新闻 |
CopyRight 2018-2019 办公设备维修网 版权所有 豫ICP备15022753号-3 |